MqttDecoder

Undocumented in source.

class MqttDecoder : ByteToMessageDecoder!(MqttMsg[]) {

this(int maxBytesInMessage);

void read(Context ctx, ubyte[] msg);

bool decode(Context ctx, ubyte[] buf, MqttMsg[] mqs);

}

Constructors

this this(): Undocumented in source.
this this(int maxBytesInMessage): Undocumented in source.

Members

Functions

decode bool decode(Context ctx, ubyte[] buf, MqttMsg[] mqs): Undocumented in source. Be warned that the author may not have intended to support it.
read void read(Context ctx, ubyte[] msg): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

collie codec mqtt mqttdecoder classes